import org.apache.spark.{SparkConf, SparkContext}

//TODO 使用Spark实现将文件数组{3,2,6,7,8,10,,9,5}中的数据读入RDD并对每个元素值+2，然后打印修改后的每个元素

object spark基本操作 {

  def main(args: Array[String]): Unit = {

    val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("spark基本操作")

    val sc = new SparkContext(config)

    val rdd = sc.parallelize(Array(3,2,6,7,8,10,9,5))

    val rdd_file = sc.textFile("作业/resources/spark基本操作.txt").map(_.split(","))

    rdd_file.foreach(println)

    val rdd_new = rdd.map(_+2)

    rdd_new.foreach(println)
  }

}
